package jobs

import (
	"log"
)

var TestTopic = "TestJob"

type TestJob struct{}

func NewTestJob() *TestJob {
	return &TestJob{}
}

func (t *TestJob) Register(job *JobMessage) {
	log.Println("测试延时任务被执行...", *job)
}
